#!/usr/bin/python
# -*- coding:utf-8 -*-
from kafka import SimpleClient
from kafka import SimpleProducer
kafkaclient = SimpleClient("linux1:9092,linux2:9092,linux3:9092")
producer = SimpleProducer(kafkaclient, async=True)
producer.send_messages("topic_kafka","Test Data")